package com.gemframe.kafka;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

@EnableBinding(Sink.class)
public class KafkaReceiver {
 
 
	@StreamListener(Sink.INPUT_1)
	private void receive(String vote) {
		System.out.println(vote);
	}
	
}
